//  连接数据库
const mysql = require('mysql')
const sqlconfig = require('../config/mysqlconfig')
// 创建连接池
const pool = mysql.createPool(sqlconfig)
// 连接
const exec = (sql,values) => {
  return new Promise((resolve, reject) => {
    pool.getConnection((err, conn) => {
      if (err) {
        //连接错误
        reject(err)
      } else {
        // 查询
        conn.query(sql,values, (err, data) => {
          if (err) {
            console.log(err);
            //操作失败
            reject({
              code: 0,
              message: '操作失败!',

            })
          } else {
            resolve(data)
          }
        })
      }
    // 当连接不再使用时,归还到连接池
    conn.release()
    })
  })
}
module.exports = {
  exec
}